package org.codingq92.kafka;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class KafkaCusConsumer {

    @KafkaListener(topics = "topic01", groupId = "group01")
    public void receive(String message) {
        System.out.println();
        System.out.println("Received message: " + message);
        System.out.println();
    }
}
